package com.rpc.test.client.flow.sub.flow.sub4.flows;

import rpc.core.BaseAsyncFlow;
import rpc.core.FlowRes;
import rpc.core.annotations.Flow;

@Flow("client.flow2")
public class Flow2 extends BaseAsyncFlow {

  @Override
  public void enter() {
    reply(new FlowRes(req.toMap()).append("retIndex", req.l("index") + 1));
  }
}
